/*
package com.wang.rabbitmq.springboot.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

*/
/**
 * @author: wang
 * @date: 2021/8/3 20:32
 * @description:
 *//*

@Configuration
public class RabbitMQConfig {


    //@Bean
    //public DirectExchange directExchange() {
    //    return new DirectExchange("directExchange");
    //}
    //
    //@Bean
    //public Queue getQueue() {
    //    return new Queue("directQueue");
    //}
    //
    //@Bean
    //public Binding getBinding(DirectExchange getExchange, Queue getQueue) {
    //    return BindingBuilder.bind(getQueue).to(getExchange).with("direct");
    //}

    //@Bean
    //public FanoutExchange fanoutExchange() {
    //    return new FanoutExchange("fanoutExchange");
    //}

    @Bean
    public TopicExchange getTopicExchange() {
        return new TopicExchange("topicExchange");
    }

    @Bean
    public Queue getTopicQueue1() {
        return new Queue("topicQueue1");
    }

    @Bean
    public Queue getTopicQueue2() {
        return new Queue("topicQueue2");
    }
    @Bean
    public Queue getTopicQueue3() {
        return new Queue("topicQueue3");
    }

    @Bean
    public Binding bindTopic1(TopicExchange getTopicExchange, Queue getTopicQueue1){
        return BindingBuilder.bind(getTopicQueue1).to(getTopicExchange).with("a");
    }

    @Bean
    public Binding bindTopic2(TopicExchange getTopicExchange, Queue getTopicQueue2){
        return BindingBuilder.bind(getTopicQueue2).to(getTopicExchange).with("a.*");
    }

    @Bean
    public Binding bindTopic3(TopicExchange getTopicExchange, Queue getTopicQueue3){
        return BindingBuilder.bind(getTopicQueue3).to(getTopicExchange).with("a.#");
    }






}
*/
